package com.xueshan.disruptor.lmax.consumer;

import com.xueshan.disruptor.common.util.CalulateTwoLanLon;
import com.xueshan.disruptor.lmax.event.LongEvent;
import lombok.extern.slf4j.Slf4j;

/**
 * created with IDEA
 *
 * @author:huqm
 * @date:2021/3/16
 * @time:17:43 <p>
 *
 * </p>
 */
@Slf4j
public class MyConsumer extends DisruptorConsumer<LongEvent> {


    public void consume(LongEvent data) {
        log.info("点对点数据{},{}",Thread.currentThread(),data.getLat1());
        CalulateTwoLanLon.getDistance(22.75424,112.76535 , 23.014171, 113.10111);
    }


}